package com.littleken.order.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface StreamClient {

    String INPUT = "myMessage";

    String RETUEN = "myMessage2";

    @Input(StreamClient.INPUT)
    SubscribableChannel input();

    @Output(StreamClient.INPUT)
    MessageChannel output();


    @Input(StreamClient.RETUEN)
    SubscribableChannel inputRETUEN();

    @Output(StreamClient.RETUEN)
    MessageChannel outputRETUEN();
}
